package com.navinfo.tripanalysis.service.impl;

import com.navinfo.tripanalysis.common.arithmetic.common.OuterEventData;
import com.navinfo.tripanalysis.common.arithmetic.convert.EventDataParquetConvert;
import com.navinfo.tripanalysis.service.LoadEventDataService;
import org.apache.spark.sql.Row;

/**
 * 从hive表加载事件
 * @author 沈东生
 */
public class LoadEventServiceHiveImpl extends AbstractLoadDataHive<OuterEventData> implements LoadEventDataService {

    @Override
    protected OuterEventData fromRow(Row row) {
        return EventDataParquetConvert.fromRow(row);
    }
}
